//package com.jihui.enterprise.event;
//
//import com.fasterxml.jackson.databind.ObjectMapper;
//import com.jihui.enterprise.common.SmsTemplateCodeEnum;
//
//import com.jihui.common.constant.YtxKafkaTopics;
//import org.apache.commons.collections.MapUtils;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//import java.io.IOException;
//import java.util.HashMap;
//import java.util.Map;
//
///**
// * 卖家审核事件
// *
// * @author hxz
// * @since 2017/04/19 15:27
// */
//@Component
//public class SellerAuditEvent {
//    @Autowired
//    private ObjectMapper objectMapper;
//    @Autowired
//    private AccountService accountService;
//    @Autowired
//    private AccountRepository accountRepository;
//
//    private final Logger logger = LoggerFactory.getLogger(getClass());
//
//    //卖家审核成功事件
//    @KafkaListener(topics = YtxKafkaTopics.SELLER_AUDIT_PASS)
//    public void processSellerAuditPass(String message) {
//        logger.warn("收到卖家审核成功消息：{}", message);
//        handleSendMsg(message, YtxKafkaTopics.SELLER_AUDIT_PASS);
//    }
//
//    //卖家审核失败事件
//    @KafkaListener(topics = YtxKafkaTopics.SELLER_AUDIT_FAIL)
//    public void processSellerAuditFail(String message) {
//        logger.warn("收到卖家审核失败消息：{}", message);
//        handleSendMsg(message, YtxKafkaTopics.SELLER_AUDIT_FAIL);
//    }
//
//    private void handleSendMsg(String message, String channel) {
//        try {
//            Map map = objectMapper.readValue(message, Map.class);
//
//            Long buyerAccountId = MapUtils.getLong(map, "accountId");
//            String contactMobile = MapUtils.getString(map, "contactMobile");
//            String contactName = MapUtils.getString(map, "contactName");
//
//            if (channel.equals(YtxKafkaTopics.SELLER_AUDIT_FAIL)) {
//                Map<String, String> params = new HashMap<>();
//                params.put("name", contactName);
//                accountService.sendYtxSms(contactMobile, SmsTemplateCodeEnum.SMS_66670274.getCode(),params,null);
//            } else {
//                Map<String, String> params = new HashMap<>();
//                params.put("name", contactName);
//                accountService.sendYtxSms(contactMobile, SmsTemplateCodeEnum.SMS_66830201.getCode(), params, null);
//
//                String name = MapUtils.getString(map, "name");
//                String password = MapUtils.getString(map, "password");
//                //发送密码到手机
//                params = new HashMap<>();
//                params.put("username", name);
//                params.put("password", password);
//                accountService.sendYtxSms(contactMobile, SmsTemplateCodeEnum.SMS_66540279.getCode(), params, null);
//            }
//
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//    }
//
//}
